#!/bin/bash

set -e
set -x

cluster_id="(cluster-id)"

# In each controller execute
/opt/kafka/bin/kafka-storage.sh format --cluster-id ${cluster_id} \
                     --config /opt/kafka/config/kraft/server.properties

set +x
set +e